Rollup protocol

byzcoin/api_test.go

@@ -228,9 +228,6 @@ func TestClient_Streaming(t *testing.T) {
 			require.NoError(t, err)
 			_, err = c.AddTransaction(tx)
 			require.NoError(t, err)
-
-			// sleep for a block interval so we create multiple blocks
-			time.Sleep(msg.BlockInterval)
 		}
 	}()
 
@@ -363,19 +360,15 @@ type corruptedService struct {
 
 func newTestService(c *onet.Context) (onet.Service, error) {
 	s := &Service{
-		ServiceProcessor:       onet.NewServiceProcessor(c),
-		contracts:              newContractRegistry(),
-		txBuffer:               newTxBuffer(),
-		storage:                &bcStorage{},
-		darcToSc:               make(map[string]skipchain.SkipBlockID),
-		stateChangeCache:       newStateChangeCache(),
-		stateChangeStorage:     newStateChangeStorage(c),
-		heartbeatsTimeout:      make(chan string, 1),
-		closeLeaderMonitorChan: make(chan bool, 1),
-		heartbeats:             newHeartbeats(),
-		viewChangeMan:          newViewChangeManager(),
-		streamingMan:           streamingManager{},
-		closed:                 true,
+		ServiceProcessor:   onet.NewServiceProcessor(c),
+		contracts:          newContractRegistry(),
+		storage:            &bcStorage{},
+		darcToSc:           make(map[string]skipchain.SkipBlockID),
+		stateChangeCache:   newStateChangeCache(),
+		stateChangeStorage: newStateChangeStorage(c),
+		viewChangeMan:      newViewChangeManager(),
+		streamingMan:       streamingManager{},
+		closed:             true,
 	}
 
 	cs := &corruptedService{Service: s}