scala - How to send a process to multiple sinks in scalaz-stream -

-

if have simple process emitting values of type string , wish send these multiple sinks (i.e. each sink gets sent string), how do this?

for example, running program:

object play extends app {    def prepend(s: string): string => string = s ++ _   val out1 = io.stdoutlines.map(prepend("1-") andthen _)   val out2 = io.stdoutlines.map(prepend("2-") andthen _)    val p = io.stdinlines (out1 merge out2)   p.run.run }

the output looks like:

a     //input 1-a b     //input 2-b c     //input 2-c d     //input 1-d

i want output this:

a     //input 1-a 2-a b     //input 2-b 1-b c     //input 2-c 1-c d     //input 1-d 2-d

edit

i can achieve follows:

implicit class toboth[o](p: process[task, o]) {   def toboth(s1: sink[task, o], s2: sink[task, o]): process[task, unit] = {     (for (o <- p; n <- process.emit(o) ++ process.emit(o)) yield n) (s1 interleave s2)   } }

that is, duplicate input , interleave output. can generalized:

def toall(sinks: sink[task, o] *): process[task, unit] = {   (for (o <- p; n <- process.emitall(sinks.map(_ => o))) yield n) sinks.reduceleftoption(_ interleave _).getorelse(process.empty) }

edit 2

i realized generalization toall not work. toboth does, though

is there better (built-in) way?

you use observe , to attach multiple sinks process:

val p = io.stdinlines.observe(out1).to(out2)

observe to echoes passed sink. io.stdinlines.observe(out1) still emits strings come stdin (that means of type process[task, string]) sends them sink out1.

as eric pointed out, possible zip sinks together. here more elaborate example sends individual lines of logfile different sinks depending on log level:

sealed trait loglevel case object info extends loglevel case object debug extends loglevel case object warning extends loglevel  case class line(level: loglevel, line: string)  val outinfo = io.stdoutlines.contramap((l: line) => "i: " + l.line) val outdebug = io.stdoutlines.contramap((l: line) => "d: " + l.line) val outwarning = io.stdoutlines.contramap((l: line) => "w: " + l.line)  val zipped = outinfo.zip(outdebug).zip(outwarning).map {   case ((finfo, fdebug), fwarning) =>     (l: line) => l.level match {       case info    => finfo(l)       case debug   => fdebug(l)       case warning => fwarning(l)     } }  val lines = list(   line(info, "hello"),   line(warning, "oops"),   line(debug, "ui ui"),   line(info, "world"))  process.emitall(lines).liftio.to(zipped).run.run

running output:

i: hello w: oops d: ui ui i: world

Comments

Post a Comment

Popular posts from this blog

c# - how to use buttonedit in devexpress gridcontrol -

-
Image
i trying create gridcontrol buttonedit in 1 of columns. when user clicks button edit, popups form select product. when selection done on popup, returns datarow selection main grid below. but when column loses focus, value wrote column disappear. here code creates gridcontrol's data , buttonedit's click event. private void frmsiparisnew_load(object sender, eventargs e) { dt = new datatable(); dt.columns.add("malzeme_kodu",typeof(string)); dt.columns.add("malzeme_aciklama", typeof(string)); dt.columns.add("adet", typeof(decimal)); dt.columns.add("birim", typeof(string)); dt.columns.add("fiyat", typeof(decimal)); dt.columns.add("kur", typeof(string)); dt.columns.add("tutar", typeof(decimal)); datarow dr = dt.newrow(); dt.rows.add(dr); gc.datasource = dt; } private void repositoryitembuttoneditmal...
Read more

java - Oracle EBS .ClassNotFoundException: oracle.apps.fnd.formsClient.FormsLauncher.class ERROR -

-
i need in configuring java on machine because, when try loading forms, loader goes in circles , gives error: java.lang.classnotfoundexception: oracle.apps.fnd.formsclient.formslauncher.class @ sun.plugin2.applet.applet2classloader.findclass(unknown source) @ sun.plugin2.applet.plugin2classloader.loadclass0(unknown source) @ sun.plugin2.applet.plugin2classloader.loadclass(unknown source) @ sun.plugin2.applet.plugin2classloader.loadclass(unknown source) @ java.lang.classloader.loadclass(unknown source) @ sun.plugin2.applet.plugin2classloader.loadcode(unknown source) @ sun.plugin2.applet.plugin2manager.createapplet(unknown source) @ sun.plugin2.applet.plugin2manager$appletexecutionrunnable.run (unknown source) @ java.lang.thread.run(unknown source) i have tried re-installing firefox, older versions of java runtime environments, disabling proxy. what missing? application working on other machines. i spent around 100 hours finding s...
Read more

c# - System.FormatException' occurred in MongoDB.Bson.dll - XXX is not a valid 24 digit hex string -

-
i have created c# class this: public class employee { [bsonrepresentation(bsontype.objectid)] public string name { get; set; } public int age { get; set; } public list<string> address { get; set; } } when try save information (using mongodb) this: var e = new employee(); e.address = new list<string>(); e.address.add("address 1"); e.address.add("address 2"); e.age = 333; e.name = "some name"; context.employees.insert(e); i getting following error: an unhandled exception of type 'system.formatexception' occurred in mongodb.bson.dll additional information: 'some name' not valid 24 digit hex string. how can make string field act objectid in mongodb? reading docs: ... in case serializer convert objectid string when reading data database , convert string objectid when writing data database ( the string value must valid objectid )...
Read more