(b []byte)
| 92 | } |
| 93 | |
| 94 | func (m *mockDataChannelWriter) Write(b []byte) (int, error) { |
| 95 | wait := time.Until(m.nextWriteCompleteAt) |
| 96 | if wait <= 0 { |
| 97 | return len(b), nil |
| 98 | } |
| 99 | select { |
| 100 | case <-m.deadline.Done(): |
| 101 | return 0, m.deadline.Err() |
| 102 | case <-time.After(wait): |
| 103 | return len(b), nil |
| 104 | } |
| 105 | } |
| 106 | |
| 107 | func (m *mockDataChannelWriter) SetWriteDeadline(t time.Time) error { |
| 108 | m.deadline.Set(t) |