go/ferret
1
0
Fork 0
mirror of https://github.com/MontFerret/ferret.git synced 2025-08-15 20:02:56 +02:00
Code Issues Releases Activity

fix go routines leakage (#726)

Browse Source 
* fix go routines leakage

* Update manager.go

fmt

Co-authored-by: Tim Voronov <ziflex@users.noreply.github.com>
This commit is contained in:
Roman
2022-02-10 23:42:07 +03:00
committed by GitHub
parent 0c6d4e6401
commit 70a8ef790b
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
pkg/drivers/cdp/network/manager.go
View File

@@ -494,17 +494,16 @@ func (m *Manager) NavigateBack(ctx context.Context, skip values.Int) (values.Boo
} }
func (m *Manager) WaitForNavigation(ctx context.Context, opts WaitEventOptions) error { func (m *Manager) WaitForNavigation(ctx context.Context, opts WaitEventOptions) error {
ctx, cancel := context.WithCancel(ctx)
defer cancel()
stream, err := m.OnNavigation(ctx) stream, err := m.OnNavigation(ctx)
if err != nil { if err != nil {
return err return err
} }
defer stream.Close(ctx) defer stream.Close(ctx)
ctx, cancel := context.WithCancel(ctx)
defer cancel()
for evt := range stream.Read(ctx) { for evt := range stream.Read(ctx) {
if err := ctx.Err(); err != nil { if err := ctx.Err(); err != nil {
return err return err