in out_writeapi.go [301:309]
func rebuildPredicate(err error) bool {
if apiErr, ok := apierror.FromError(err); ok {
storageErr := &storagepb.StorageError{}
if e := apiErr.Details().ExtractProtoMessage(storageErr); e != nil {
return storageErr.GetCode() == storagepb.StorageError_INVALID_STREAM_TYPE
}
}
return false
}