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

Copy Markdown View Source

Useful and internal functions for manipulating streams.

Summary

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)

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)