Transform AmazonS3 senden an RX android beobachtbar

Question

Wie würde ich diesen asynchronen Anruf zu RX Android zu transformieren und die Fähigkeit haben, um es auf andere Anrufe zu ketten? Momentan verwende ich EventBus, um zu informieren, dass Senden erfolgreich oder fehlgeschlagen ist, aber ich möchte RX hauptsächlich für Verkettungszwecke verwenden.

public void SendToAmazon(Intent i) { 
    try { 
     // take params from intent 
     // ....................... 

     // Create an S3 client 
     s3Client = new AmazonS3Client(new BasicAWSCredentials(MY_ACCESS_KEY_ID, MY_SECRET_KEY)); 
     // Set the region of your S3 bucket 
     s3Client.setRegion(com.amazonaws.regions.Region.getRegion(Regions.EU_CENTRAL_1)); 

     String newFilename = fileName+"/img.jpg"; 
     PutObjectRequest putObjectRequest = new PutObjectRequest(
       AmazonS3FetchParams.MY_BUCKET_NAME, newFilename, new java.io.File(fileURI)) 
       .withCannedAcl(CannedAccessControlList.PublicRead) 
       .withStorageClass(StorageClass.Standard); 
     try { 
      putObjectRequest.setGeneralProgressListener(new S3ProgressListener() { 
       @Override 
       public void onPersistableTransfer(PersistableTransfer persistableTransfer) { 

       } 

       @Override 
       public void progressChanged(com.amazonaws.event.ProgressEvent progressEvent) { 
        if (progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) { 
         Log.d("Info", "TRANSFER finished: " + progressEvent.getBytesTransferred() + " bytes"); 
         SentToS3Event sentEvent = new SentToS3Event(fileName, fileURI, position, 
           0, from, nrRetry, messageDbId, getAmazonImageUrl(fileName)); 
         EventBus.getDefault().post(sentEvent); 
        } else if (progressEvent.getEventCode() == ProgressEvent.FAILED_EVENT_CODE) { 
         SentToS3Event sentEvent = new SentToS3Event(fileName, fileURI, position, 
           -1, from, nrRetry, messageDbId, getAmazonImageUrl(fileName)); 
         EventBus.getDefault().post(sentEvent); 
        } 
       } 
      }); 

      PutObjectResult objectResult = s3Client.putObject(putObjectRequest); 
      error = 0; 
     } catch (AmazonClientException aex) { 
      Log.e("Info", "AMAZON EXCEPTION ! " + aex.getMessage()); 
     } 
    } catch (Exception e) { 
     error = -1; 
    } 
} 

`

Answer 1

einen Blick auf dieses Stück Code nehmen. Ich habe es geschafft, es in einer anderen Situation funktionieren zu lassen.

final PutObjectRequest putObjectRequest = new PutObjectRequest("a", "b", "c"); 
    Observable.create(new Observable.OnSubscribe<SomeAmazonModel>() { 
     @Override 
     public void call(final Subscriber<? super SomeAmazonModel> subscriber) { 
      putObjectRequest.setGeneralProgressListener(new S3ProgressListener() { 
       @Override 
       public void onPersistableTransfer(PersistableTransfer persistableTransfer) { 

       } 

       @Override 
       public void progressChanged(com.amazonaws.event.ProgressEvent progressEvent) { 
        if (progressEvent.getEventCode() == ProgressEvent.COMPLETED_EVENT_CODE) { 
         subscriber.onNext(new SomeAmazonModel(ProgressEvent.COMPLETED_EVENT_CODE)); 
         subscriber.onCompleted(); 
        } else if (progressEvent.getEventCode() == ProgressEvent.FAILED_EVENT_CODE) { 
         subscriber.onNext(new SomeAmazonModel(ProgressEvent.COMPLETED_EVENT_CODE)); 
        } 
       } 
      }); 
     } 
    }).subscribe(new Action1<SomeAmazonModel>() { 
     @Override 
     public void call(SomeAmazonModel someAmazonModel) { 
      // Subscribe to above Observable and handle result 
      someAmazonModel.getEventCode(); 
     } 
    });