Avi Kivity af1c015526 core: add stream/subscription abstraction ...

The future/promise pair is for single-shot use only, which makes it
less useful for repetitive processing.

Add a stream/subscription abstraction, where a stream can produce data
which is repetitively consumed by the subscription.  End-or-stream (or
error condition) is provided by a future.

Inspired by Dart's Stream class.

2014-09-22 11:25:54 +03:00

..

apply.hh

build: organize files into a directory structure

2014-08-31 21:29:13 +03:00

array_map.hh

array_map: introduce at()

2014-09-16 18:48:14 +03:00

bitset-iter.hh

Import timer wheel code from OSv

2014-09-01 13:01:06 +03:00

deleter.hh

net: spit out packet class into its own files

2014-09-16 10:13:09 +03:00

future.hh

future: implement available()

2014-09-22 11:25:54 +03:00

posix.hh

posix: add signalfd wrappers

2014-09-08 15:23:59 +03:00

print.hh

core: add format_separated()

2014-09-10 13:44:46 +03:00

queue.hh

Add a future-friendly queue template

2014-09-14 15:57:39 +03:00

reactor.cc

Allow providing options to configure network stacks

2014-09-17 17:44:58 +03:00

reactor.hh

Allow providing options to configure network stacks

2014-09-17 17:44:58 +03:00

shared_ptr.hh

Add specializations to make_shared

2014-09-03 16:22:27 +03:00

sstring.hh

sstring: add conversion from std::string

2014-09-10 13:45:54 +03:00

stream.hh

core: add stream/subscription abstraction

2014-09-22 11:25:54 +03:00

temporary_buffer.hh

spit out temporary_buffer into its own file

2014-09-17 12:42:30 +03:00

timer-set.hh

Import timer wheel code from OSv

2014-09-01 13:01:06 +03:00

vla.hh

build: organize files into a directory structure

2014-08-31 21:29:13 +03:00