()
| 199 | } |
| 200 | |
| 201 | func (b *Bridge) openJobStream() error { |
| 202 | stream, err := b.rpc.JobStream(b.listenerContext()) |
| 203 | if err != nil { |
| 204 | return err |
| 205 | } |
| 206 | b.jobStream = stream |
| 207 | return nil |
| 208 | } |
| 209 | |
| 210 | func (b *Bridge) openSpiteStream() error { |
| 211 | stream, err := b.rpc.SpiteStream(b.pipelineContext()) |