base watcher implementation

1 files changed, 0 insertions, 5 deletions

diff --git a/state.go b/state.go
index 4d8b1eaa..8a065637 100644
--- a/state.go
+++ b/state.go
@@ -26,9 +26,6 @@ const (
 	// StateWorking - working on given payload.
 	StateWorking
 
-	// StateStreaming - indicates that worker is streaming the data at the moment.
-	StateStreaming
-
 	// StateStopping - process is being softly stopped.
 	StateStopping
 
@@ -57,8 +54,6 @@ func (s *state) String() string {
 		return "ready"
 	case StateWorking:
 		return "working"
-	case StateStreaming:
-		return "streaming"
 	case StateStopped:
 		return "stopped"
 	case StateErrored: