RetroSearch Browse

Showing content from https://github.com/cloudevents/sdk-go/commit/13825ba9352b19327bce2e925ad219fb502b4ccc below:

File tree Expand file treeCollapse file tree 2 files changed

-3

lines changed

Filter options

Expand file treeCollapse file tree 2 files changed

-3

lines changed Original file line number Diff line number Diff line change


 @@ -104,7 +104,7 @@ func testSenderReceiver(t testing.TB) (func(), bindings.Sender, bindings.Receive

104 104 105 105


 // Not perfect but we need to give OpenInbound() as chance to start

106 106


 // as it's a race condition. I couldn't find something on 'p' to wait for

107

-
 time.Sleep(15 * time.Second)

107

+
 time.Sleep(6 * time.Second)

108 108 109 109


 return func() {

110 110


 require.NoError(t, p.Close(context.TODO()))

Original file line number Diff line number Diff line change


 @@ -31,7 +31,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even

31 31


 wg.Add(2)

32 32 33 33


 // Give time for Kafka client protocol to get setup

34

-
 time.Sleep(5 * time.Second)

34

+
 time.Sleep(2 * time.Second)

35 35 36 36


 go func() {

37 37


 ctx, cancel := context.WithCancel(context.TODO())


 @@ -54,7 +54,7 @@ func SendReceive(t *testing.T, protocolFactory func() interface{}, in event.Even

54 54

}()

55 55 56 56


 // Give time for the receiever to start

57

-
 time.Sleep(5 * time.Second)

57

+
 time.Sleep(2 * time.Second)

58 58 59 59


 go func() {

60 60


 defer wg.Done()

You can’t perform that action at this time.

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4