Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1739)

Issues Search
    My Issues | Starred     Open | Closed | All

Unified Diff: runtime/bin/file_impl.dart

Issue 9652001: SendPort + ReceivePort changes: (Closed) Base URL: https://dart.googlecode.com/svn/branches/bleeding_edge/dart
Patch Set: Created 8 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View side-by-side diff with in-line comments
Download patch
« lib/isolate/isolate_api.dart ('K') | « runtime/bin/directory_impl.dart ('k') | runtime/lib/isolate.dart » ('j') | tests/isolate/src/TestFramework.dart » ('J')
Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
Index: runtime/bin/file_impl.dart
diff --git a/runtime/bin/file_impl.dart b/runtime/bin/file_impl.dart
index 8ab5bbbf29afdd5e61c5212dd2c4bdf2f46cc393..3a999776db9bf66f9c6445343e6d912e0a6c97ee 100644
--- a/runtime/bin/file_impl.dart
+++ b/runtime/bin/file_impl.dart
@@ -330,7 +330,7 @@ class _File implements File {
List request = new List(2);
request[0] = _FileUtils.kExistsRequest;
request[1] = _name;
- _fileService.call(request).receive((exists, replyTo) {
+ _fileService.call(request).then((exists) {
callback(exists);
});
}
@@ -352,7 +352,7 @@ class _File implements File {
List request = new List(2);
request[0] = _FileUtils.kCreateRequest;
request[1] = _name;
- _fileService.call(request).receive((created, replyTo) {
+ _fileService.call(request).then((created) {
if (created) {
callback();
} else if (_onError != null) {
@@ -378,7 +378,7 @@ class _File implements File {
List request = new List(2);
request[0] = _FileUtils.kDeleteRequest;
request[1] = _name;
- _fileService.call(request).receive((deleted, replyTo) {
+ _fileService.call(request).then((deleted) {
if (deleted) {
callback();
} else if (_onError != null) {
@@ -404,7 +404,7 @@ class _File implements File {
List request = new List(2);
request[0] = _FileUtils.kDirectoryRequest;
request[1] = _name;
- _fileService.call(request).receive((path, replyTo) {
+ _fileService.call(request).then((path) {
if (path != null) {
callback(new Directory(path));
} else if (_onError != null) {
@@ -440,7 +440,7 @@ class _File implements File {
request[0] = _FileUtils.kOpenRequest;
request[1] = _name;
request[2] = mode._mode; // Direct int value for serialization.
- _fileService.call(request).receive((id, replyTo) {
+ _fileService.call(request).then((id) {
if (id != 0) {
callback(new _RandomAccessFile(id, _name));
} else if (_onError != null) {
@@ -481,7 +481,7 @@ class _File implements File {
List request = new List(2);
request[0] = _FileUtils.kFullPathRequest;
request[1] = _name;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != null) {
callback(result);
} else if (_onError != null) {
@@ -664,7 +664,7 @@ class _RandomAccessFile implements RandomAccessFile {
// Set the id_ to 0 (NULL) to ensure the no more async requests
// can be issues for this file.
_id = 0;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != -1) {
_id = result;
callback();
@@ -692,7 +692,7 @@ class _RandomAccessFile implements RandomAccessFile {
List request = new List(2);
request[0] = _FileUtils.kReadByteRequest;
request[1] = _id;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != -1) {
callback(result);
} else if (_onError != null) {
@@ -727,7 +727,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[0] = _FileUtils.kReadListRequest;
request[1] = _id;
request[2] = bytes;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result is List && result.length == 2 && result[0] != -1) {
var read = result[0];
var data = result[1];
@@ -775,7 +775,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[1] = _id;
request[2] = value;
_writeEnqueued();
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
_writeCompleted();
if (result == -1 && _onError !== null) {
_onError("writeByte failed");
@@ -820,7 +820,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[3] = outOffset;
request[4] = bytes;
_writeEnqueued();
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
_writeCompleted();
if (result == -1 && _onError !== null) {
_onError("writeList failed");
@@ -857,7 +857,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[1] = _id;
request[2] = string;
_writeEnqueued();
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
_writeCompleted();
if (result == -1 && _onError !== null) {
_onError("writeString failed");
@@ -883,7 +883,7 @@ class _RandomAccessFile implements RandomAccessFile {
List request = new List(2);
request[0] = _FileUtils.kPositionRequest;
request[1] = _id;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != -1) {
callback(result);
} else if (_onError != null) {
@@ -911,7 +911,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[0] = _FileUtils.kSetPositionRequest;
request[1] = _id;
request[2] = position;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result) {
callback();
} else if (_onError != null) {
@@ -939,7 +939,7 @@ class _RandomAccessFile implements RandomAccessFile {
request[0] = _FileUtils.kTruncateRequest;
request[1] = _id;
request[2] = length;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result) {
callback();
} else if (_onError != null) {
@@ -965,7 +965,7 @@ class _RandomAccessFile implements RandomAccessFile {
List request = new List(2);
request[0] = _FileUtils.kLengthRequest;
request[1] = _id;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != -1) {
callback(result);
} else if (_onError != null) {
@@ -992,7 +992,7 @@ class _RandomAccessFile implements RandomAccessFile {
List request = new List(2);
request[0] = _FileUtils.kFlushRequest;
request[1] = _id;
- _fileService.call(request).receive((result, replyTo) {
+ _fileService.call(request).then((result) {
if (result != -1) {
callback();
} else if (_onError != null) {
« lib/isolate/isolate_api.dart ('K') | « runtime/bin/directory_impl.dart ('k') | runtime/lib/isolate.dart » ('j') | tests/isolate/src/TestFramework.dart » ('J')

Powered by Google App Engine
This is Rietveld 408576698