Remove Queue Oracle
This commit is contained in:
parent
186a33deb6
commit
de32ae240a
|
@ -120,9 +120,6 @@ func TestFileSharing(t *testing.T) {
|
||||||
alice.AutoHandleEvents([]event.Type{event.PeerStateChange, event.NewRetValMessageFromPeer})
|
alice.AutoHandleEvents([]event.Type{event.PeerStateChange, event.NewRetValMessageFromPeer})
|
||||||
bob.AutoHandleEvents([]event.Type{event.PeerStateChange, event.NewRetValMessageFromPeer})
|
bob.AutoHandleEvents([]event.Type{event.PeerStateChange, event.NewRetValMessageFromPeer})
|
||||||
|
|
||||||
queueOracle := event.NewQueue()
|
|
||||||
app.GetEventBus(bob.GetOnion()).Subscribe(event.FileDownloaded, queueOracle)
|
|
||||||
|
|
||||||
// Turn on File Sharing Experiment...
|
// Turn on File Sharing Experiment...
|
||||||
settings := app.ReadSettings()
|
settings := app.ReadSettings()
|
||||||
settings.ExperimentsEnabled = true
|
settings.ExperimentsEnabled = true
|
||||||
|
@ -171,7 +168,6 @@ func TestFileSharing(t *testing.T) {
|
||||||
t.Fatalf("cwthc.png should have been automatically downloadeded...")
|
t.Fatalf("cwthc.png should have been automatically downloadeded...")
|
||||||
}
|
}
|
||||||
|
|
||||||
queueOracle.Shutdown()
|
|
||||||
app.Shutdown()
|
app.Shutdown()
|
||||||
acn.Close()
|
acn.Close()
|
||||||
time.Sleep(10 * time.Second)
|
time.Sleep(10 * time.Second)
|
||||||
|
|
Loading…
Reference in New Issue