GRPC.Stream.Operators (gRPC Server v1.0.3)

Useful and internal functions for manipulating streams.

Summary

Types

item()

reason()

Functions

ask(stream, target, timeout \\ 5000)

ask!(stream, target, timeout \\ 5000)

effect(stream, effect_fun)

filter(stream, filter)

flat_map(stream, flat_mapper)

map(stream, mapper)

map_error(stream, func)

map_with_context(stream, mapper)

partition(stream, options \\ [])

reduce(stream, acc_fun, reducer_fun)

reject(stream, filter)

uniq(stream)

uniq_by(stream, fun)

Types

item()

@type item() :: any()

reason()

@type reason() :: any()

Functions

ask(stream, target, timeout \\ 5000)

ask!(stream, target, timeout \\ 5000)

effect(stream, effect_fun)

filter(stream, filter)

flat_map(stream, flat_mapper)

map(stream, mapper)

map_error(stream, func)

map_with_context(stream, mapper)

partition(stream, options \\ [])

reduce(stream, acc_fun, reducer_fun)

reject(stream, filter)

uniq(stream)

uniq_by(stream, fun)