S3TaskClientImpl implements S3TaskClient { @Override public DeleteStreamingTaskResult deleteStreaming(String spaceId) throws ContentStoreException { DeleteStreamingTaskParameters taskParams = new DeleteStreamingTaskParameters(); taskParams.setSpaceId(spaceId); return DeleteStreamingTaskResult.deserialize( contentStore.performTask(StorageTaskConstants.DELETE_STREAMING_TASK_NAME, taskParams.serialize())); } S3TaskClientImpl(ContentStore contentStore); @Override EnableStreamingTaskResult enableStreaming(String spaceId, boolean secure); @Override DisableStreamingTaskResult disableStreaming(String spaceId); @Override DeleteStreamingTaskResult deleteStreaming(String spaceId); @Override GetUrlTaskResult getUrl(String spaceId,
                                   String contentId,
                                   String resourcePrefix); @Override GetSignedUrlTaskResult getSignedUrl(String spaceId,
                                               String contentId,
                                               String resourcePrefix); @Override GetSignedUrlTaskResult getSignedUrl(String spaceId,
                                               String contentId,
                                               String resourcePrefix,
                                               int minutesToExpire,
                                               String ipAddress); @Override EnableStreamingTaskResult enableHlsStreaming(String spaceId, boolean secure); @Override DisableStreamingTaskResult disableHlsStreaming(String spaceId); @Override DeleteStreamingTaskResult deleteHlsStreaming(String spaceId); @Override GetUrlTaskResult getHlsUrl(String spaceId, String contentId); @Override GetSignedCookiesUrlTaskResult getSignedCookiesUrl(String spaceId,
                                                             String ipAddress,
                                                             int minutesToExpire,
                                                             String redirectUrl);  }
@Test public void testDeleteStreaming() throws Exception { String taskName = StorageTaskConstants.DELETE_STREAMING_TASK_NAME; DeleteStreamingTaskResult preparedResult = new DeleteStreamingTaskResult(); preparedResult.setResult(completionResult); setupMock(taskName, preparedResult.serialize()); replayMocks(); DeleteStreamingTaskResult result = taskClient.deleteStreaming(spaceId); assertThat(completionResult, equalTo(result.getResult())); }