Skip to main content
se añadieron 120 caracteres en el cuerpo
Origen Enlace
Luis
  • 1.6k
  • 9
  • 9

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 
{
    var found = false;
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        // abres la conexión 
        await connection.OpenAsync();     
        // haces el query     
        await reader.ReadAsync();
        // obtienes el resultado
        found = ... 
    }
    // bla bla bla
   return found;
} 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamosUtilizamos el objeto Observable
    .Interval(TimeSpan.FromMinutes(2))    // utilizamos interval para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query con el valor obtenuido en el select anterior y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos (del resultado del selectmany)
    .Subscribe(_ => this.Close()); // cerramos la ventana al terminar

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system"System. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.Observables.Linq;

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 
{
    var found = false;
    using (SqlConnection connection = new SqlConnection(connectionString)
   {
        // abres la conexión 
        await connection.OpenAsync();     
        // haces el query     
        await reader.ReadAsync();
        // obtienes el resultado
        found = ... 
    }
    // bla bla bla
   return found;
} 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamos el Observable
    .Interval(TimeSpan.FromMinutes(2))    // para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos
    .Subscribe(_ => this.Close()); // cerramos la ventana

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.Observables.Linq;

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 
{
    var found = false;
    using (SqlConnection connection = new SqlConnection(connectionString))
    {
        // abres la conexión 
        await connection.OpenAsync();     
        // haces el query     
        await reader.ReadAsync();
        // obtienes el resultado
        found = ... 
    }
    // bla bla bla
   return found;
} 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // Utilizamos el objeto Observable
    .Interval(TimeSpan.FromMinutes(2))    // utilizamos interval para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query con el valor obtenuido en el select anterior y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos (del resultado del selectmany)
    .Subscribe(_ => this.Close()); // cerramos la ventana al terminar

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "System. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.Observables.Linq;
se añadieron 236 caracteres en el cuerpo
Origen Enlace
Luis
  • 1.6k
  • 9
  • 9

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 
{
    var found = false;
    using (SqlConnection connection = new SqlConnection(connectionString)
   {
        // abres la conexión 
        await connection.OpenAsync();     
        // haces el query     
        await reader.ReadAsync();
        // obtienes el resultado
        found = ... 
    }
    // bla bla bla
   return found;
} 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamos el Observable
    .Interval(TimeSpan.FromMinutes(2))    // para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos
    .Subscribe(_ => this.Close()); // cerramos la ventana

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.observablesObservables.Linq;

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamos el Observable
    .Interval(TimeSpan.FromMinutes(2))    // para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos
    .Subscribe(_ => this.Close()); // cerramos la ventana

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.observables.Linq;

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 
{
    var found = false;
    using (SqlConnection connection = new SqlConnection(connectionString)
   {
        // abres la conexión 
        await connection.OpenAsync();     
        // haces el query     
        await reader.ReadAsync();
        // obtienes el resultado
        found = ... 
    }
    // bla bla bla
   return found;
} 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamos el Observable
    .Interval(TimeSpan.FromMinutes(2))    // para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos
    .Subscribe(_ => this.Close()); // cerramos la ventana

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.Observables.Linq;
Origen Enlace
Luis
  • 1.6k
  • 9
  • 9

Aparte de SignalR yo recomiendo entrar en las Reactive Extensions, permite manejar de una mejor manera operaciones asíncronas:

// en algún lugar tienes un método que realiza la búsqueda de forma asíncrona 
private async Task<bool> RandomExiste(int randomVal) 

    
// ya en la parte donde vas a crear el "timer"   
Observable  // creamos el Observable
    .Interval(TimeSpan.FromMinutes(2))    // para que emita cada dos minutos
    .Select(_ => a) // obtenemos el valor random que generaste
    .SelectMany(async randomABuscar => await claseConMetodos.RandomExiste(randomABuscar)) // ejecutamos la query y nos regresa true o false
    .Where(resultado => !resultado) // filtramos que solo procese los resultados falsos
    .Subscribe(_ => this.Close()); // cerramos la ventana

claseConMetodos es tu clase donde tienes tus métodos para operaciones crud, y RandomExiste realiza una búsqueda pasándole el número random cómo parámetro, y regresa verdadero o falso.

Agregas el paquete nuget llamado "system. Reactive", y donde vayas a utilizar los Observable solo necesitas agregar:

using System.Observables;
using System.observables.Linq;