michaelbukachi

interface Callback<S> {
    fun success(s: S)
    fun error(e: Exception)
}

fun<T> doSomethingLong(callback: Callback<T>) {
    
}

private suspend fun  <T> someFuncAwait() :T = suspendCancellableCoroutine {

michaelbukachi

import websockets
import asyncio 


async def hello():
    uri = 'wss://api.forkdelta.app/socket.io/'
    async with websockets.connect(uri,) as websocket:
    # await websocket.send('getMarket')
        await websocket.send('getMarket')
        res = await websocket.recv()

michaelbukachi

import threading
import time


def func1():
    print('Starting func 1')
    end_time = time.time() + 5

    i = 0
    while time.time() < end_time:

michaelbukachi

package farmdrive.ripe.utils

import android.Manifest
import android.content.Context
import android.content.pm.PackageManager
import android.location.Location
import androidx.core.app.ActivityCompat
import com.google.android.gms.common.ConnectionResult
import com.google.android.gms.common.GoogleApiAvailability
import com.google.android.gms.location.*

michaelbukachi

// load canvas with id 'c'
const canvas = new fabric.Canvas('c');
// use canvas height as the height limit
var limit = canvas.height;

var text = new fabric.Textbox('Some very long text');
// set initial values
text.set({
    top: margin,
    width: canvas.width,

michaelbukachi

'''
This workaround helps avoid:
 sqlalchemy.exc.InvalidRequestError: No transaction is begun
 whenever you try to create/update a model when `autocommit=True`
'''
class BaseModelView(ModelView):

    def create_model(self, form):
        self.session.begin()
        super(BaseModelView, self).create_model(form)

michaelbukachi

/**
* Checkout https://gist.github.com/Triodes/b54aea95aceeb160c23d for an android implementation
*
**/
import com.google.gson.Gson;
import com.google.gson.JsonIOException;
import com.google.gson.JsonSyntaxException;
import com.google.gson.reflect.TypeToken;
import java.io.FileNotFoundException;
import java.io.FileReader;

michaelbukachi

import io.realm.*
import io.realm.kotlin.where
import kotlinx.coroutines.GlobalScope
import kotlinx.coroutines.launch
import kotlinx.coroutines.suspendCancellableCoroutine
import kotlin.coroutines.resume
import kotlin.coroutines.resumeWithException

private suspend fun <T: RealmObject, S: RealmQuery<T>> findAllAwait(query: S): RealmResults<T> = suspendCancellableCoroutine { continuation ->
    val listener = RealmChangeListener<RealmResults<T>> { t -> continuation.resume(t) }

michaelbukachi

From https://youtrack.jetbrains.com/issue/PY-12988#focus=Comments-27-4122075.0-0

We are using https://github.com/pre-commit/pre-commit-hooks for hooks and this is a really annoying issue This is how I solved it for now (linux only but can be ported to windows) The only requirement is to be in your root folder with the virtualenv activated when you install the hooks this is my shell script in /usr/bin/install_pre_commit_hooks.sh:

#!/bin/bash

pre-commit install