We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
2 parents 69d7ba5 + 817dd81 commit fcec891Copy full SHA for fcec891
lib/grpc/stream.ex
@@ -300,15 +300,15 @@ defmodule GRPC.Stream do
300
defdelegate filter(stream, filter), to: Operators
301
302
@doc """
303
- Applies a mapping function and flattens the results (one level deep).
+ Applies a function to each entry and concatenates the resulting lists.
304
305
Useful for emitting multiple messages for each input.
306
"""
307
@spec flat_map(t, (term -> Enumerable.t())) :: t()
308
defdelegate flat_map(stream, flat_mapper), to: Operators
309
310
311
- Applies a transformation function to each stream item.
+ Applies a function to each stream item.
312
313
@spec map(t(), (term -> term)) :: t()
314
defdelegate map(stream, mapper), to: Operators
0 commit comments