Skip to content

Commit 55666ef

Browse files
fix merge update
1 parent 9182ef8 commit 55666ef

File tree

2 files changed

+3
-3
lines changed

2 files changed

+3
-3
lines changed

core/livepeernode.go

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -181,6 +181,8 @@ type LivePipeline struct {
181181
Pipeline string
182182
ControlPub *trickle.TricklePublisher
183183
StopControl func()
184+
ReportUpdate func([]byte)
185+
DataWriter *media.SegmentWriter
184186

185187
StreamCtx context.Context
186188
streamCancel context.CancelCauseFunc
@@ -217,8 +219,6 @@ func (p *LivePipeline) StreamRequest() []byte {
217219
func (p *LivePipeline) StopStream(err error) {
218220
p.StopControl()
219221
p.streamCancel(err)
220-
DataWriter *media.SegmentWriter
221-
ReportUpdate func([]byte)
222222
}
223223

224224
// NewLivepeerNode creates a new Livepeer Node. Eth can be nil.

server/job_stream.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -897,7 +897,7 @@ func (ls *LivepeerServer) UpdateStream() http.Handler {
897897
}
898898

899899
params := string(data)
900-
stream.Params = params
900+
stream.Params = data
901901
controlPub := stream.ControlPub
902902

903903
if controlPub == nil {

0 commit comments

Comments
 (0)