room/rxjava2/src/main/java/androidx/room/RxRoom.java
@RestrictTo(RestrictTo.Scope.LIBRARY_GROUP)
    public static <T> Flowable<T> createFlowable(final RoomDatabase database,
            final String[] tableNames, final Callable<T> callable) {
        final Maybe<T> maybe = Maybe.fromCallable(callable);
        return createFlowable(database, tableNames).observeOn(sAppToolkitIOScheduler)
                .flatMapMaybe(new Function<Object, MaybeSource<T>>() {
                    @Override
                    public MaybeSource<T> apply(Object o) throws Exception {
                        return maybe;
                    }
                });
    }
/**
     * Helper method used by generated code to bind a Callable such that it will be run in
     * our disk io thread and will automatically block null values since RxJava2 does not like null.
     *
     * @hide
     */
Helper method used by generated code to bind a Callable such that it will be run in
our disk io thread and will automatically block null values since RxJava2 does not like null.

@hide
Helper method used by generated code to bind a Callable such that it will be run in our disk io thread and will automatically block null values since RxJava2 does not like null . @hide
@RestrictTo(RestrictTo.Scope.LIBRARY_GROUP)
    public static <T> Flowable<T> createFlowable(final RoomDatabase database,
            final String[] tableNames, final Callable<T> callable) {
        final Maybe<T> maybe = Maybe.fromCallable(callable);
        return createFlowable(database, tableNames).observeOn(sAppToolkitIOScheduler)
                .flatMapMaybe(new Function<Object, MaybeSource<T>>() {
                    @Override
                    public MaybeSource<T> apply(Object o) throws Exception {
                        return maybe;
                    }
                });
    }
@ RestrictTo ( RestrictTo . Scope . LIBRARY_GROUP ) public static < T > Flowable < T > createFlowable ( final RoomDatabase database , final String [ ] tableNames , final Callable < T > callable ) { final Maybe < T > maybe = Maybe . fromCallable ( callable ) ; return createFlowable ( database , tableNames ) . observeOn ( sAppToolkitIOScheduler ) . flatMapMaybe ( new Function < Object , MaybeSource < T > > ( ) { @ Override public MaybeSource < T > apply ( Object o ) throws Exception { return maybe ; } } ) ; }
Helper method used by generated code to bind a Callable such that it will be run in
 our disk io thread and will automatically block null values since RxJava2 does not like null.
Helper method used by generated code to bind a Callable such that it will be run in our disk io thread and will automatically block null values since RxJava2 does not like null .