From mboxrd@z Thu Jan  1 00:00:00 1970
X-Spam-Checker-Version: SpamAssassin 3.4.4 (2020-01-24) on polar.synack.me
X-Spam-Level: 
X-Spam-Status: No, score=-1.9 required=5.0 tests=BAYES_00,FREEMAIL_FROM
	autolearn=unavailable autolearn_force=no version=3.4.4
X-Received: by 10.182.65.134 with SMTP id x6mr9223158obs.14.1445454598583;
        Wed, 21 Oct 2015 12:09:58 -0700 (PDT)
X-Received: by 10.182.232.166 with SMTP id tp6mr53768obc.10.1445454598560;
 Wed, 21 Oct 2015 12:09:58 -0700 (PDT)
Path: 
 eternal-september.org!reader01.eternal-september.org!reader02.eternal-september.org!news.eternal-september.org!mx02.eternal-september.org!feeder.eternal-september.org!news.glorb.com!kq10no24876760igb.0!news-out.google.com!z4ni27871ign.0!nntp.google.com!kq10no20848241igb.0!postnews.google.com!glegroupsg2000goo.googlegroups.com!not-for-mail
Newsgroups: comp.lang.ada
Date: Wed, 21 Oct 2015 12:09:58 -0700 (PDT)
In-Reply-To: <18xpt5oxiz5nw$.klh515586pjp.dlg@40tude.net>
Complaints-To: groups-abuse@google.com
Injection-Info: glegroupsg2000goo.googlegroups.com; posting-host=46.218.2.213;
 posting-account=21X1fwoAAABfSGdxRzzAXr3Ux_KE3tHr
NNTP-Posting-Host: 46.218.2.213
References: <mvlopk$49j$1@dont-email.me>
 <75f38e30-42ba-4e98-8f36-2218b5167209@googlegroups.com>
 <1wvo1b25eaa4o$.1y03vu1to6vux$.dlg@40tude.net>
 <f729172a-a3e2-48ba-9e88-72dc34727a88@googlegroups.com>
 <18xpt5oxiz5nw$.klh515586pjp.dlg@40tude.net>
User-Agent: G2/1.0
MIME-Version: 1.0
Message-ID: <3a82a370-2175-4cf6-90e1-64fb19d794ff@googlegroups.com>
Subject: Re: Musings on RxAda
From: Hadrien Grasland <hadrien.grasland@gmail.com>
Injection-Date: Wed, 21 Oct 2015 19:09:58 +0000
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
Xref: news.eternal-september.org comp.lang.ada:28020
Date: 2015-10-21T12:09:58-07:00
List-Id: <comp.lang.ada>

So you would essentially store a pipeline of data and operations in some co=
ntainer, then perform all of them on the same thread when the output of the=
 pipeline is requested ?

This seems much more complex to implement to me, since your operation queue=
 needs to be able to store data of any type and operation function pointers=
, all in a type-safe way. As far as I can tell, you cannot use streams for =
that because a stream requires you to know what you are reading from it.