ExGitEngine.GitStream (ex_git_engine v0.9.1)

Functions for creating and transforming Git streamable resources.

Summary

Types

t()

Functions

new(resource \\ nil, acc, next_fun)

Creates a new stream.

transform(stream, next_fun)

Transforms the given stream.

Types

t()

@type t() :: %ExGitEngine.GitStream{__ref__: reference(), enum: Enumerable.t()}

Functions

new(resource \\ nil, acc, next_fun)

@spec new(reference() | nil, term(), (Stream.acc() ->
                                  {[Stream.element()], Stream.acc()}
                                  | {:halt, Stream.acc()})) ::
  t()

Creates a new stream.

transform(stream, next_fun)

@spec transform(Enumerable.t(), (Stream.acc() ->
                             {[Stream.element()], Stream.acc()}
                             | {:halt, Stream.acc()})) :: t()

Transforms the given stream.