unsafe fn put(&self, d: D) {
        let val = &mut *self.val.get();
        // If the stream is not connected to any consumers, drop the output
        // on the floor.
        if val.consumers > 0 {
            val.tokens = val.consumers;
            val.val = Some(d);
        }
    }
/// Puts a value in the stream, overwriting the previous value if any.
///
/// #Safety
///
/// The caller must have exclusive access to the current stream.
Puts a value in the stream, overwriting the previous value if any.
Puts a value in the stream overwriting the previous value if any .
unsafe fn put(&self, d: D) {
        let val = &mut *self.val.get();
        // If the stream is not connected to any consumers, drop the output
        // on the floor.
        if val.consumers > 0 {
            val.tokens = val.consumers;
            val.val = Some(d);
        }
    }
unsafe fn put ( & self , d : D ) { let val = & mut * self . val . get ( ) ; // If the stream is not connected to any consumers, drop the output // on the floor. if val . consumers > 0 { val . tokens = val . consumers ; val . val = Some ( d ) ; } }
Puts a value in the stream, overwriting the previous value if any.
Puts a value in the stream overwriting the previous value if any .
&self
d
D
safety
The caller must have exclusive access to the current stream.
The caller must have exclusive access to the current stream .