Searched defs:createSource (Results 1 – 3 of 3) sorted by relevance
53 S createSource(T data) throws IOException; in createSource() method
466 auto start(F createSource, long created, long subscribed, long unsubscribed) const in start()501 auto start(F&& createSource, long unsubscribed) const in start()523 auto start(F createSource, long created, long subscribed, long unsubscribed) const in start()530 auto start(F createSource, long unsubscribed) const in start()