diff --git a/pool/impl.go b/pool/impl.go
index ee475d4..13648fd 100644
--- a/pool/impl.go
+++ b/pool/impl.go
@@ -138,7 +138,11 @@ func (c *StratumClient) Submit(jobID, nonce, result, algo string) int64 {
 			"algo":   algo,
 		},
 	}
-	_ = c.writeJSON(req)
+	if err := c.writeJSON(req); err != nil {
+		c.mu.Lock()
+		delete(c.pending, seq)
+		c.mu.Unlock()
+	}
 	return seq
 }