@@ -99,26 +99,26 @@ public final class GenericStreamReader : StreamReader {
99
99
Cannot be negative.
100
100
If 0, the reader is effectively forbidden from reading the underlying stream.
101
101
If a read operation is done that would require reading from the stream (not enough data in the buffer), the `streamReadForbidden` error is thrown. */
102
- public init ( stream: GenericReadStream , bufferSize size : Int , bufferSizeIncrement sizeIncrement : Int , readSizeLimit limit : Int ? = nil , underlyingStreamReadSizeLimit streamReadSizeLimit : Int ? = nil ) {
103
- assert ( size > 0 )
104
- assert ( sizeIncrement > 0 )
105
- assert ( limit == nil || limit ! >= 0 )
106
- assert ( streamReadSizeLimit == nil || streamReadSizeLimit ! >= 0 )
102
+ public init ( stream: GenericReadStream , bufferSize: Int , bufferSizeIncrement: Int , readSizeLimit: Int ? = nil , underlyingStreamReadSizeLimit: Int ? = nil ) {
103
+ assert ( bufferSize > 0 )
104
+ assert ( bufferSizeIncrement > 0 )
105
+ assert ( readSizeLimit == nil || readSizeLimit ! >= 0 )
106
+ assert ( underlyingStreamReadSizeLimit == nil || underlyingStreamReadSizeLimit ! >= 0 )
107
107
108
- sourceStream = stream
108
+ self . sourceStream = stream
109
109
110
- defaultBufferSize = size
111
- bufferSizeIncrement = sizeIncrement
110
+ self . defaultBufferSize = bufferSize
111
+ self . bufferSizeIncrement = bufferSizeIncrement
112
112
113
- buffer = UnsafeMutableRawPointer . allocate ( byteCount: size , alignment: MemoryLayout< UInt8> . alignment)
114
- bufferSize = size
115
- bufferStartPos = 0
116
- bufferValidLength = 0
113
+ self . buffer = UnsafeMutableRawPointer . allocate ( byteCount: bufferSize , alignment: MemoryLayout< UInt8> . alignment)
114
+ self . bufferSize = bufferSize
115
+ self . bufferStartPos = 0
116
+ self . bufferValidLength = 0
117
117
118
- currentStreamReadPosition = 0
118
+ self . currentStreamReadPosition = 0
119
119
120
- readSizeLimit = limit
121
- underlyingStreamReadSizeLimit = streamReadSizeLimit
120
+ self . readSizeLimit = readSizeLimit
121
+ self . underlyingStreamReadSizeLimit = underlyingStreamReadSizeLimit
122
122
}
123
123
124
124
deinit {
0 commit comments