(meta *wshrpc.StreamMeta)
| 100 | } |
| 101 | |
| 102 | func (b *Broker) CreateStreamWriter(meta *wshrpc.StreamMeta) (*Writer, error) { |
| 103 | writer := NewWriter(meta.Id, meta.RWnd, b) |
| 104 | err := b.AttachStreamWriter(meta, writer) |
| 105 | if err != nil { |
| 106 | return nil, err |
| 107 | } |
| 108 | return writer, nil |
| 109 | } |
| 110 | |
| 111 | func (b *Broker) SendAck(ackPk wshrpc.CommandStreamAckData) { |
| 112 | b.sendQueue.Enqueue(workItem{workType: "sendack", ackPk: ackPk}) |