func isInStream(in reflect.Type) bool {
    recvMethod, exists := in.MethodByName("Recv")
    if !exists {
        return false
    }