scala - Akka streams flattening Flows via -


flows can connected via like:

def atob: flow[a, b, notused] = { ??? }   def btoc: flow[b, c, notused] = { ??? }   def atoc: flow[a, c, notused] = { atob.via(btoc) }

i equivalent of flatmap:

def atosomeb: flow[a, some[b], notused] = { ??? }   def atosomec: flow[a, some[c], notused] = { atosomeb.flatvia(btoc) }

is there built-in way flatvia? seems common need things option unwrapping , error flattening.

it depends if interested in keeping nones around, or if want throw them away.

as typed flow flow[a, some[c], notused] seems not interested in nones @ all. means can filter them out collect, e.g.

def atosomec: flow[a, c, notused] = { atosomeb.collect{case some(x) ⇒ x}.via(btoc) }

if, otherwise, need track nones (or lefts if you're dealing eithers), you'll need write "lifting" stage yourself. can written generically. example, can written function takes flow flow[i, o, m] , returns flow flow[either[e, i], either[e, o], m]. because requires fan-out , fan-in stages, usage of graphdsl required.

  def lifteither[i, o, e, m](f: flow[i, o, m]): graph[flowshape[either[e, i], either[e, o]], m] =     flow.fromgraph(graphdsl.create(f) { implicit builder: graphdsl.builder[m] => f =>        val fin      = builder.add(flow[either[e, i]])       val p        = builder.add(partition[either[e, i]](2, _.fold(_ ⇒ 0, _ ⇒ 1)))       val merge    = builder.add(merge[either[e, o]](2))       val toright  = builder.add(flow[o].map(right(_)))                   p.out(0).collect{case left(x) ⇒ left(x)}             ~> merge       fin.out ~> p.in                  p.out(1).collect{case(right(x)) ⇒ x} ~> f ~> toright ~> merge        new flowshape(fin.in, merge.out)     })

this can used per below

  def atosomeb: flow[a, either[throwable, b], notused] = ???   def atosomec: flow[a, either[throwable, c], notused] = atosomeb.via(lifteither(btoc))

note options can converted eithers leverage same helper function.


Comments

Post a Comment

Popular posts from this blog

resizing Telegram inline keyboard -

telegram's inline keyboard great feature lots of different use cases. inline buttons added list of items this: inline_keyboard = [[inlinekeyboardbutton(text="button", callback_data="button"), inlinekeyboardbutton(text="reset",callback_data="reset")]] inline_keyboard_markup = inlinekeyboardmarkup(inline_keyboard) update.message.reply_text("hi", reply_markup=inline_keyboard_markup) the above code adds 2 buttons each half width of chat screen. i know the normal keyboard button there resize_keyboard parameter somehow can used. my question is there way resize inline buttons ? example make full width or quarter width. unfortunately, can't now. :( you can suggest @botsupport , might add feature next version.
Read more

javascript - How to bind ViewModel Store to View? -

i'm pretty new ext js , trying embed multiselect inside panel . the viewmodel has stores property can see here: ext.define('test.view.controls.search.searchfiltermodel', { extend: 'ext.app.viewmodel', alias: 'viewmodel.filter', data: { title: '' }, stores: { test: { fields: [ 'id', 'name' ], proxy: { type: 'ajax', url: 'api/test', reader: 'array' }, autoload: true } } }); i bind in view this: viewmodel: { type: 'filter' }, layout: 'fit', border: 1, plain: true, scrollable: 'y', layout: 'fit', bind: { title: '{title}', }, items: { xtype: 'multiselect', scrollable: false, allowblank: true, ddreorder: true, bind: { store: '{test}' }, valuefield: 'id', displayfield: 'name' } ...
Read more

c - Why does alarm() cause fgets() to stop waiting? -

i playing around signals in c. main function asks input using fgets(name, 30, stdin) , , sits there , waits. set alarm alarm(3) , , reassigned sigalrm call function myalarm calls system("say pay attention") . after alarm goes off, fgets() stops waiting input , main fn continues on. happens if change myalarm set variable , nothing it. void myalarm(int sig) { //system("say pay attention"); int x = 0; } int catch_signal(int sig, void (*handler)(int)) { // when signal comes in, "catch" , "handle it" in way want struct sigaction action; // create new sigaction action.sa_handler = handler; // set it's sa_handler attribute function specified in header sigemptyset(&action.sa_mask); // "turn signals in sa_mask off?" "set sa_mask contian no signals, i.e. nothing masked?" action.sa_flags = 0; // not sure, looks aren't using of available flags, whatever may return sigaction(sig, ...
Read more