AttachReader starts reading from the given reader
(r io.Reader)
| 80 | |
| 81 | // AttachReader starts reading from the given reader |
| 82 | func (sm *StreamManager) AttachReader(r io.Reader) error { |
| 83 | sm.lock.Lock() |
| 84 | defer sm.lock.Unlock() |
| 85 | |
| 86 | if sm.reader != nil { |
| 87 | return fmt.Errorf("reader already attached") |
| 88 | } |
| 89 | |
| 90 | sm.reader = r |
| 91 | go sm.readLoop() |
| 92 | |
| 93 | return nil |
| 94 | } |
| 95 | |
| 96 | // ClientConnected transitions to CONNECTED mode |
| 97 | func (sm *StreamManager) ClientConnected(streamId string, dataSender DataSender, rwndSize int, clientSeq int64) (int64, error) { |