Searched refs:createSource (Results 1 – 5 of 5) sorted by relevance
/external/guava/guava-tests/test/com/google/common/io/ |
D | SourceSinkFactories.java | 107 public CharSource createSource(String string) throws IOException { in asCharSourceFactory() 108 return factory.createSource(string.getBytes(Charsets.UTF_8)) in asCharSourceFactory() 159 public ByteSource createSource(byte[] bytes) throws IOException { 160 return factory.createSource(bytes).slice(off, len); 179 public CharSource createSource(String data) throws IOException { 196 public ByteSource createSource(byte[] bytes) throws IOException { 213 public CharSource createSource(String data) throws IOException { 230 public ByteSource createSource(byte[] bytes) throws IOException { 271 public ByteSource createSource(byte[] bytes) throws IOException { 341 public CharSource createSource(String string) throws IOException { [all …]
|
D | SourceSinkFactory.java | 59 S createSource(T data) throws IOException; in createSource() method
|
D | CharSourceTester.java | 75 this.source = factory.createSource(data); in setUp()
|
D | ByteSourceTester.java | 105 source = factory.createSource(data); in setUp()
|
/external/Reactive-Extensions/RxCpp/Rx/v2/src/rxcpp/schedulers/ |
D | rx-test.hpp | 466 auto start(F createSource, long created, long subscribed, long unsubscribed) const in start() argument 472 typedef decltype(createSource()) source_type; in start() 485 schedule_absolute(created, [createSource, state](const schedulable&) { in start() 486 state->source.reset(new typename state_type::source_type(createSource())); in start() 501 auto start(F&& createSource, long unsubscribed) const in start() argument 504 … return start<T>(std::forward<F>(createSource), created_time, subscribed_time, unsubscribed); in start() 508 auto start(F&& createSource) const in start() 511 … return start<T>(std::forward<F>(createSource), created_time, subscribed_time, unsubscribed_time); in start() 523 auto start(F createSource, long created, long subscribed, long unsubscribed) const in start() argument 526 …return start<rxu::value_type_t<start_traits<F>>>(std::move(createSource), created, subscribed, uns… in start() [all …]
|