Changeset 605 for trunk/ab5.0/ablib/src/Classes/System/IO/Stream.ab

Timestamp:

Aug 21, 2008, 7:21:48 PM (16 years ago)

Author:

イグトランス (egtra)

Message:

非同期入出力(Begin/End-Read/Writeメソッド)を実装。

File:

• trunk/ab5.0/ablib/src/Classes/System/IO/Stream.ab (modified) (5 diffs)

trunk/ab5.0/ablib/src/Classes/System/IO/Stream.ab

@@ -4 +4 @@
 
 Class Stream
-    Implements System.IDisposable
+    Implements IDisposable
 
-Public 'Protected
+Protected
     Sub Stream()
     End Sub
 Public
-    Virtual Sub ~Stream()
+    Sub ~Stream()
         This.Dispose(False)
     End Sub
@@ -18 +18 @@
 
     Virtual Function CanTimeout() As Boolean
-        Return True
+        Return False
     End Function
 
     Abstract Function CanWrite() As Boolean
-    Abstract Function Length() As Int64
-    Abstract Sub Position(value As Int64)
-    Abstract Function Position() As Int64
+    Abstract Function Length() As QWord
+    Abstract Sub Position(value As QWord)
+    Abstract Function Position() As QWord
 
     Virtual Sub ReadTimeout(value As Long)
-        ' Throw InvalidOperationException
+        Throw New InvalidOperationException("Stream does not support Timeout.")
     End Sub
 
     Virtual Function ReadTimeout() As Long
-        ' Throw InvalidOperationException
+        Throw New InvalidOperationException("Stream does not support Timeout.")
     End Function
 
     Virtual Sub WriteTimeout(value As Long)
-        ' Throw InvalidOperationException
+        Throw New InvalidOperationException("Stream does not support Timeout.")
     End Sub
 
     Virtual Function WriteTimeout() As Long
-        ' Throw InvalidOperationException
+        Throw New InvalidOperationException("Stream does not support Timeout.")
     End Function
 
 Public
     Virtual Function BeginRead(buffer As *Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
-        Read(buffer,offset,count)
+        Dim r = Read(buffer,offset,count)
+        Return New Detail.SyncStreamResultImpl(r, state)
     End Function
     Virtual Function BeginWrite(buffer As *Byte, offset As Long, count As Long, callback As AsyncCallback, state As Object) As System.IAsyncResult
         Write(buffer,offset,count)
+        Return New Detail.SyncStreamResultImpl(0, state)
     End Function
     Sub Close()
@@ -56 +58 @@
     End Sub
     Virtual Function EndRead(asyncResult As System.IAsyncResult) As Long
+        Dim ar = asyncResult As Detail.IAsyncStreamResult
+        EndRead = ar.WaitAndGetResult
     End Function
     Virtual Sub EndWrite(asyncResult As System.IAsyncResult)
@@ -73 +77 @@
 
     Abstract Function Seek(offset As Int64, origin As SeekOrigin) As Int64
-    Abstract Sub SetLength(value As Int64)
+    Abstract Sub SetLength(value As QWord)
     Abstract Sub Write(buffer As *Byte, offset As Long, count As Long)
     Virtual Sub WriteByte(b As Byte)
@@ -81 +85 @@
     Virtual Sub Dispose(disposing As Boolean)
     End Sub
-    Virtual Function CreateWaitHandle() As System.Threading.WaitHandle
-    End Function
 End Class