Searched defs:createSource (Results 1 – 2 of 2) sorted by relevance
59 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()