protected override FilterResult Filter<TByteBlock>(
ref TByteBlock byteBlock,
bool beCached,
ref TCountSpliterRequestInfo request
)
where TByteBlock : IBytesReader
Protected Overrides Function Filter(Of TByteBlock As IBytesReader) (
ByRef byteBlock As TByteBlock,
beCached As Boolean,
ByRef request As TCountSpliterRequestInfo
) As FilterResultabstract Filter :
byteBlock : 'TByteBlock byref *
beCached : bool *
request : 'TCountSpliterRequestInfo byref -> FilterResult when 'TByteBlock : IBytesReader
override Filter :
byteBlock : 'TByteBlock byref *
beCached : bool *
request : 'TCountSpliterRequestInfo byref -> FilterResult when 'TByteBlock : IBytesReader此方法实现了核心的数据分割逻辑:
如果分隔符计数不足,方法返回Cache以等待更多数据。