Searched defs:abortable (Results 1 – 12 of 12) sorted by relevance
34 private Abortable abortable; field in SyncTimeoutTask41 public void abortable(Abortable abortable) { in abortable() argument
27 default void abortable(Abortable abortable) { in abortable() method
50 void abortable(Abortable abortable); in abortable() argument
48 public void abortable(Abortable abortable) { in abortable() method in NoOpTimeoutTracker
57 public void abortable(Abortable abortable) { in abortable() method in ApiCallTimeoutTracker
34 private final Abortable abortable; field in AbortableInputStream36 private AbortableInputStream(InputStream delegate, Abortable abortable) { in AbortableInputStream()48 public static AbortableInputStream create(InputStream delegate, Abortable abortable) { in create()
12 pub fn abortable<St>(stream: St) -> (Abortable<St>, AbortHandle) in abortable() function17 let abortable = assert_stream::<St::Item, _>(Abortable::new(stream, reg)); in abortable() localVariable
133 mod abortable; module
12 pub fn abortable<Fut>(future: Fut) -> (Abortable<Fut>, AbortHandle) in abortable() function17 let abortable = assert_future::<Result<Fut::Output, Aborted>, _>(Abortable::new(future, reg)); in abortable() localVariable
119 mod abortable; module
39 private final Abortable abortable; field in ResponseInputStream
329 mod abortable; module