This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| use bus::{Bus, BusReader}; | |
| use futures::task::{Context, Poll}; | |
| use futures::Stream; | |
| use std::pin::Pin; | |
| use std::sync::{Arc, Mutex}; | |
| /// `SourceInner` contains the reference to the Bus. `SourceInner` is available to the | |
| /// `Source` instance, as well as its connected `SourceNode`. The `inner` needs to be wrapped | |
| /// around a `Mutex` so that it's possible to include new receivers, and around a `Arc` so that | |
| /// the instance is cloneable, potentially from multiple threads. |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| interface Cases<O, T, E, R> { | |
| ok: (value: O) => T; | |
| err: (value: E) => R; | |
| } | |
| export abstract class Result<O, E> { | |
| public abstract isOk(): boolean; |
OlderNewer