Skip to content

Commit

Permalink
Update dependencies (#2)
Browse files Browse the repository at this point in the history
  • Loading branch information
mikeharder committed Nov 1, 2019
1 parent dc35062 commit 9c631bb
Show file tree
Hide file tree
Showing 7 changed files with 11 additions and 19 deletions.
2 changes: 1 addition & 1 deletion java/azure-perfstress/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -39,7 +39,7 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-core-http-netty</artifactId>
<version>1.0.0-preview.6</version>
<version>1.0.0</version>
</dependency>
</dependencies>

Expand Down
2 changes: 1 addition & 1 deletion java/azure-storage-blob-perfstress/pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,7 @@
<dependency>
<groupId>com.azure</groupId>
<artifactId>azure-storage-blob</artifactId>
<version>12.0.0-preview.4</version>
<version>12.0.0-preview.5</version>
</dependency>
<dependency>
<groupId>com.azure</groupId>
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ public DownloadTest(SizeOptions options) {

public Mono<Void> GlobalSetupAsync() {
return super.GlobalSetupAsync()
.then(_blobAsyncClient.upload(RandomFlux.create(Options.Size), new ParallelTransferOptions()))
.then(_blobAsyncClient.upload(RandomFlux.create(Options.Size), null))
.then();
}

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,17 +18,17 @@ public Mono<Void> GlobalSetupAsync() {
return super.GlobalSetupAsync().then(
Flux.range(0, Options.Count)
.map(i -> "getblobstest-" + UUID.randomUUID())
.flatMap(b -> BlobContainerAsyncClient.getBlobAsyncClient(b).upload(Flux.empty(), new ParallelTransferOptions()))
.flatMap(b -> BlobContainerAsyncClient.getBlobAsyncClient(b).upload(Flux.empty(), null))
.then());
}

@Override
public void Run() {
BlobContainerClient.listBlobsFlat().forEach(b -> {});
BlobContainerClient.listBlobs().forEach(b -> {});
}

@Override
public Mono<Void> RunAsync() {
return BlobContainerAsyncClient.listBlobsFlat().then();
return BlobContainerAsyncClient.listBlobs().then();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -16,15 +16,11 @@ public UploadBlockBlobTest(SizeOptions options) {

@Override
public void Run() {
try {
_blockBlobClient.upload(RandomStream.create(Options.Size), Options.Size);
} catch (IOException e) {
throw new RuntimeException(e);
}
_blockBlobClient.upload(RandomStream.create(Options.Size), Options.Size, true);
}

@Override
public Mono<Void> RunAsync() {
return _blockBlobAsyncClient.upload(RandomFlux.create(Options.Size), Options.Size).then();
return _blockBlobAsyncClient.upload(RandomFlux.create(Options.Size), Options.Size, true).then();
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -57,15 +57,11 @@ private Mono<Void> DeleteTempFile() {

@Override
public void Run() {
try {
_blobClient.uploadFromFile(tempFile.toString());
} catch (IOException e) {
throw new RuntimeException(e);
}
_blobClient.uploadFromFile(tempFile.toString(), true);
}

@Override
public Mono<Void> RunAsync() {
return _blobAsyncClient.uploadFromFile(tempFile.toString());
return _blobAsyncClient.uploadFromFile(tempFile.toString(), true);
}
}
Original file line number Diff line number Diff line change
Expand Up @@ -19,6 +19,6 @@ public void Run() {

@Override
public Mono<Void> RunAsync() {
return _blobAsyncClient.upload(RandomFlux.create(Options.Size), null).then();
return _blobAsyncClient.upload(RandomFlux.create(Options.Size), null, true).then();
}
}

0 comments on commit 9c631bb

Please sign in to comment.