Commit306e75a

committed

Code cleanup.

1 parent69f13c2 commit306e75aCopy full SHA for 306e75a

File tree

-21

lines changed

-21

lines changed

Lines changed: 2 additions & 16 deletions

Original file line number	Diff line number	Diff line change
`@@ -65,22 +65,8 @@ void OnStopped(Subscription s, Exception ex)`
`65`	`65`	`{`
`66`	`66`	`provider.Subscribe(subscription);`
`67`	`67`
`68`		`-while(!cancellationToken.IsCancellationRequested)`
`69`		`-{`
`70`		`-try`
`71`		`-{`
`72`		`-if(!awaitchannel.Reader.WaitToReadAsync(cancellationToken).NoWait())`
`73`		`-yieldbreak;`
`74`		`-}`
`75`		`-catch(Exception)`
`76`		`-{`
`77`		`-if(!cancellationToken.IsCancellationRequested)`
`78`		`-throw;`
`79`		`-}`
`80`		`-`
`81`		`-while(channel.Reader.TryRead(outvaritem))`
`82`		`-yieldreturnitem;`
`83`		`-}`
	`68`	`+awaitforeach(variteminchannel.Reader.ReadAllAsync(cancellationToken).WithEnforcedCancellation(cancellationToken))`
	`69`	`+yieldreturnitem;`
`84`	`70`	`}`
`85`	`71`	`finally`
`86`	`72`	`{`

Lines changed: 2 additions & 5 deletions

Original file line number	Diff line number	Diff line change
`@@ -121,11 +121,8 @@ void OnOut(Message msg)`
`121`	`121`	`{`
`122`	`122`	`awaitadapter.SendInMessageAsync((Message)subscription,cancellationToken);`
`123`	`123`
`124`		`-while(awaitchannel.Reader.WaitToReadAsync(cancellationToken).NoWait())`
`125`		`-{`
`126`		`-while(channel.Reader.TryRead(outvaritem))`
`127`		`-yieldreturnitem;`
`128`		`-}`
	`124`	`+awaitforeach(variteminchannel.Reader.ReadAllAsync(cancellationToken).WithEnforcedCancellation(cancellationToken))`
	`125`	`+yieldreturnitem;`
`129`	`126`	`}`
`130`	`127`	`finally`
`131`	`128`	`{`

Comments

(0)