Fork me on GitHub
#core-async
<
2017-04-07
>
mingp17:04:58

@dergutemoritz In the context of working with sequences, I’ve usually heard of that operation called “zip” (example from Python 3: https://docs.python.org/3/library/functions.html#zip), so maybe some variation of that?

dergutemoritz07:04:33

Thanks! Not quite the same, though - a zip operation usually produces a stream of items which are combined from all inputs. This is already provided by core.async's map (if you pass something like vector as the mapping function, that is).

dergutemoritz07:04:03

I want a flat stream of items just like merge produces

mingp16:04:09

Oh, I see. Not quite what I expected, then. Sorry, that one I'm not familiar with.

dergutemoritz19:04:47

Thanks for your thoughts!

mingp02:04:16

You're welcome. Sorry I couldn't be of more help.

wei18:04:39

what’s a good way to tell when a channel is dropping inputs?

serioga19:04:19

@wei I user custom implementation of the buffer (sliding-buffer in my case). This allowed me to write messages in log when items are dropped.

wei21:04:43

@serioga care to post your custom implementation of sliding buffer?