Fix typo of SubscribeTask

examples/basic/server/main.go

@@ -102,7 +102,7 @@ func (p *basicMessageProcessor) ProcessMessage(
 		log.Infof("Created streaming task %s for processing", taskID)
 
 		// Subscribe to the task for streaming events
-		subscriber, err := handle.SubScribeTask(&taskID)
+		subscriber, err := handle.SubscribeTask(&taskID)
 		if err != nil {
 			return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 		}

examples/jwks/server/main.go

@@ -92,7 +92,7 @@ func (p *pushNotificationMessageProcessor) ProcessMessage(
 	}
 
 	// Subscribe to the task for streaming events
-	subscriber, err := handle.SubScribeTask(&taskID)
+	subscriber, err := handle.SubscribeTask(&taskID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 	}

examples/simple/server/main.go

@@ -77,7 +77,7 @@ func (p *simpleMessageProcessor) ProcessMessage(
 	}
 
 	// Subscribe to the task for streaming events
-	subscriber, err := handler.SubScribeTask(&taskID)
+	subscriber, err := handler.SubscribeTask(&taskID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 	}

examples/streaming/server/main.go

@@ -75,7 +75,7 @@ func (p *streamingMessageProcessor) ProcessMessage(
 	}
 
 	// Subscribe to the task for streaming events
-	subscriber, err := handle.SubScribeTask(&taskID)
+	subscriber, err := handle.SubscribeTask(&taskID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 	}

taskmanager/interface.go

@@ -54,8 +54,8 @@ type TaskHandler interface {
 	// AddArtifact adds an artifact to the specified task.
 	AddArtifact(taskID *string, artifact protocol.Artifact, isFinal bool, needMoreData bool) error
 
-	// SubScribeTask subscribes to the task and returns the task subscriber.
-	SubScribeTask(taskID *string) (TaskSubscriber, error)
+	// SubscribeTask subscribes to the task and returns the task subscriber.
+	SubscribeTask(taskID *string) (TaskSubscriber, error)
 
 	// GetTask returns the task by taskID. Returns an error if the task cannot be found.
 	GetTask(taskID *string) (CancellableTask, error)

taskmanager/memory_handler.go

@@ -72,8 +72,8 @@ func (h *memoryTaskHandler) UpdateTaskState(
 	return nil
 }
 
-// SubScribeTask subscribes to the task
-func (h *memoryTaskHandler) SubScribeTask(taskID *string) (TaskSubscriber, error) {
+// SubscribeTask subscribes to the task
+func (h *memoryTaskHandler) SubscribeTask(taskID *string) (TaskSubscriber, error) {
 	if taskID == nil || *taskID == "" {
 		return nil, fmt.Errorf("taskID cannot be nil or empty")
 	}

taskmanager/memory_handler_test.go

@@ -128,7 +128,7 @@ func TestMemoryTaskHandler_AddArtifact(t *testing.T) {
 	}
 }
 
-func TestMemoryTaskHandler_SubScribeTask(t *testing.T) {
+func TestMemoryTaskHandler_SubscribeTask(t *testing.T) {
 	handler, _ := setupTestHandler(t)
 
 	// First create a task
@@ -138,7 +138,7 @@ func TestMemoryTaskHandler_SubScribeTask(t *testing.T) {
 	}
 
 	// Subscribe to task
-	subscriber, err := handler.SubScribeTask(&taskID)
+	subscriber, err := handler.SubscribeTask(&taskID)
 	if err != nil {
 		t.Errorf("Unexpected error: %v", err)
 	}
@@ -304,9 +304,9 @@ func TestTaskHandlerErrors(t *testing.T) {
 		}
 	})
 
-	t.Run("SubScribeTask_NonExistentTask", func(t *testing.T) {
+	t.Run("SubscribeTask_NonExistentTask", func(t *testing.T) {
 		nonExistentTaskID := "non-existent-task"
-		_, err := handler.SubScribeTask(&nonExistentTaskID)
+		_, err := handler.SubscribeTask(&nonExistentTaskID)
 		if err == nil {
 			t.Error("Expected error for non-existent task")
 		}
@@ -339,7 +339,7 @@ func TestTaskHandlerErrors(t *testing.T) {
 			t.Error("Expected error for nil task ID")
 		}
 
-		_, err = handler.SubScribeTask(nil)
+		_, err = handler.SubscribeTask(nil)
 		if err == nil {
 			t.Error("Expected error for nil task ID")
 		}

taskmanager/memory_test.go

@@ -194,7 +194,7 @@ func TestMemoryTaskManager_OnSendMessageStream(t *testing.T) {
 				return nil, err
 			}
 
-			subscriber, err := handle.SubScribeTask(&taskID)
+			subscriber, err := handle.SubscribeTask(&taskID)
 			if err != nil {
 				return nil, err
 			}

taskmanager/redis/example/server/main.go

@@ -118,7 +118,7 @@ func (p *ToLowerProcessor) processStreamingMode(
 	}
 
 	// Subscribe to the task
-	subscriber, err := handle.SubScribeTask(&taskID)
+	subscriber, err := handle.SubscribeTask(&taskID)
 	if err != nil {
 		return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 	}

taskmanager/redis/redis_task_handler.go

@@ -182,8 +182,8 @@ func (h *taskHandler) AddArtifact(taskID *string, artifact protocol.Artifact, is
 	return nil
 }
 
-// SubScribeTask subscribes to the task and returns a TaskSubscriber.
-func (h *taskHandler) SubScribeTask(taskID *string) (taskmanager.TaskSubscriber, error) {
+// SubscribeTask subscribes to the task and returns a TaskSubscriber.
+func (h *taskHandler) SubscribeTask(taskID *string) (taskmanager.TaskSubscriber, error) {
 	if taskID == nil || *taskID == "" {
 		return nil, fmt.Errorf("taskID cannot be nil or empty")
 	}

tests/e2e_test.go

@@ -71,7 +71,7 @@ func (p *testProcessor) ProcessMessage(
 
 	if options.Streaming {
 		// For streaming requests, process in background and return StreamingEvents
-		subscriber, err := handle.SubScribeTask(stringPtr(taskID))
+		subscriber, err := handle.SubscribeTask(stringPtr(taskID))
 		if err != nil {
 			return nil, fmt.Errorf("failed to subscribe to task: %w", err)
 		}